package com.gitee.zhanyao.cloud.mq.consumer.rocketmq;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

/**
 * @author chendm
 * @create 2021-03-10 14:34
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "zhanyao.rocketmq.consumer")
public class MQConsumerProperties {

    private String groupName;
    private String namesrvAddr;
    // 消费者线程数据量
    private Integer consumeThreadMin;
    private Integer consumeThreadMax;
    private Integer consumeMessageBatchMaxSize;

}
